// 链接数据库

const mysql = require('mysql');

// 接口详情
const dbConfig = {
    host: 'localhost',
    port:'3306',
    user: 'root',
    password: '8b6a50d02806642d',
    //  password: 'root',
    database: 'project_flower'
};
 
let connection ;

// 扔出去
const dbConnect =async (_sql)=>{
    // 创建一个链接
    connection= mysql.createConnection(dbConfig);
    connection.connect();
    // 解决异步
    let queryRes=await _query(_sql);
    // 断开链接
    connection.end();
    return queryRes;
}

// 接口异步包装
function _query(_sql){
    return new Promise((resolve,reject)=>{
        // 把_sql传到数据库处理,错误返回err,成功返回res
        connection.query(_sql, (err, res) => {
            if (err) reject(err);
            resolve(res);
        })
    })
}
module.exports= dbConnect;

